package com.navinfo.platform.dataanalysis.service;

import com.navinfo.platform.dataanalysis.dto.VehicleBaseStatisticsDay;
import com.navinfo.platform.dataanalysis.dto.VehicleBaseStatisticsWeekOrMonth;
import org.apache.spark.api.java.JavaPairRDD;
import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;
import org.apache.spark.sql.SparkSession;

import java.util.List;
import java.util.Map;

/**
 * @author wangshuai
 * @create 2018/11/27
 **/
public interface IStatisticsWeekOrMonthService {
    JavaPairRDD<Long, List<VehicleBaseStatisticsDay>> convert(Dataset<Row> dataSet, Map<String, String> configMap,SparkSession spark);

    JavaPairRDD<Long, VehicleBaseStatisticsWeekOrMonth> handle(JavaPairRDD<Long, List<VehicleBaseStatisticsDay>> javaPairRDD,
                                                               Map<String, String> configMap,
                                                               SparkSession spark);
}
